package aaa;
import redis.clients.jedis.Jedis;
public class Consumer implements Runnable {
	Jedis jedis = new Jedis("localhost");

	public void run() {

		while (true) {

			System.out.println(jedis.rpoplpush("task", "tmp-queue") + "移除了");
			try {
				Thread.sleep(100);
			} catch (Exception e) {
				e.printStackTrace();
			}
		}
	}
}
